package com.boarsoft.message.sofamq;


import com.boarsoft.message.bean.Message;
import com.boarsoft.message.sofamq.converter.SofaMsgConverter;

public class SofaMQProducerEx extends SofaMQProducer{

    private SofaMsgConverter converter;

    public void put(Message msg) throws Exception {
        io.openmessaging.api.Message m = converter.convert(msg);
        producer.send(m);
    }

    public SofaMsgConverter getConverter() {
        return converter;
    }

    public void setConverter(SofaMsgConverter converter) {
        this.converter = converter;
    }

}
